package co.edu.uniandes.bi.etl.audi.Helpers;

import java.sql.ResultSet;
import java.sql.SQLException;

import co.edu.uniandes.bi.db.TweetsDAO;

public class TweetsDB {

	private TweetsDAO tweetsDAO;

	public TweetsDB()
	{
		tweetsDAO = TweetsDAO.getInstance();
		
	}
	public void insertarTweet(String tweet)
	{
		boolean verificarTweet=verificarSiExiste(tweet);
		if(!verificarTweet)
		{
			String sentencia="insert into eventos(tipoevento, contenidoevento ) values('t','"+tweet.replace("'", "")+"')";
			tweetsDAO.ejecutarSQL(sentencia);
		}
	}
	
	private  boolean verificarSiExiste(String tweet)
	{
		String query="SELECT * FROM eventos where contenidoevento = '" + tweet.replace("'", "") + "'";
		ResultSet resultSet=tweetsDAO.hacerConsulta(query);
		if(resultSet==null)
		{
			return false;
		}else
		{
			try {
				if(!resultSet.next())
				{
					return false;
				}else
				{
					return true;
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return false;
	}
	
	public int darLlaveSurrogada(String tweet)
	{
		String query="select * from eventos where contenidoevento = '" + tweet.replace("'", "") + "'";
		ResultSet resultSet=tweetsDAO.hacerConsulta(query);
		try {
			while(resultSet.next())
			{
				int id=resultSet.getInt(1);
				System.out.println(id);
				return id;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return-1;
	}
	
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		String tweet= "Es alguien muy honesta akdshfgalkdsjfg asfdjgh sakfdjhg uwre glkasjfhglkajs asdgfsdfgsdfg sdgf sdfg s";
		TweetsDB tweetsDB=new TweetsDB();
		tweetsDB.insertarTweet(tweet);
		tweetsDB.darLlaveSurrogada(tweet);
	}
}
